//package cn.com.scfhdt.payment.receiver;
//
//import java.io.IOException;
//
//import org.springframework.amqp.rabbit.annotation.RabbitListener;
//import org.springframework.amqp.support.AmqpHeaders;
//import org.springframework.messaging.handler.annotation.Header;
//import org.springframework.messaging.handler.annotation.Payload;
//import org.springframework.stereotype.Component;
//
//import com.rabbitmq.client.Channel;
//
//import cn.com.scfhdt.payment.configuration.RabbitMQConfig;
//import cn.com.yusys.yusp.commons.web.rest.dto.ResultDto;
//import lombok.extern.slf4j.Slf4j;
//
///**
// * @description rabbitmq消息队列接收处理对象
// * @author hanjl
// * @date 2019年9月26日
// * @version 1.0.0
// * @Copyright (c) scfhdt
// */
//@Component
//@Slf4j
//public class MsgReceiver {
//	/**
//	 * @description 处理特定队列中的消息
//	 * @author hanjl
//	 * @date 2019年9月26日
//	 * @param
//	 * @return void
//	 */
//	@RabbitListener(queues = RabbitMQConfig.SCJKPRODUCT)
//	public void processSCJKPRODUCT(@Payload ResultDto<String> msg, @Header(AmqpHeaders.DELIVERY_TAG) long deliveryTag,
//			Channel channel) throws IOException {
//		try {
//			log.info(msg.getData());
//			channel.basicAck(deliveryTag, false);
//		} catch (Exception e) {
//			log.error(e.getMessage());
//			channel.basicReject(deliveryTag, false);
//		}
//	}
//}
